#!/bin/sh
topic_name=$1

echo "topic name is ${topic_name}, will reading ..."
bin/kafka-console-consumer.sh --bootstrap-server node101:9092 --topic ${topic_name} --from-beginning
